package com.wy.customer;

import com.wy.utils.Constant;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * @描述 消息的消费者，实际项目中应该和消息的生产者再不同的项目；
 *    消息的消费者，是基于监听模式。也就是说，只有发送者发送到消息到队列里边，消费者就会自动接收
 * @创建人 wangyue
 * @创建时间2019/12/1211:16
 */
@Component
@RabbitListener(queues = Constant.WORK_QUEUE)
public class Work2Receiver {

    @RabbitHandler
    public void process(Message message, String hello) {
        System.out.println("ReceiverA2  : " + hello);
    }
}
